package ThreadPool;

import java.util.ArrayList;
import java.util.concurrent.*;

/**
 * @ClassName TaskWithResult
 * @Description Runnable是执行工作的独立任务, 但是它不返回任何值。如果你希望任务在完成时能够返
 *      * 回一个值,那么可以实现 Callable接口而不是 Runnable接口。在 Java se5中引入的 Callabel是
 *      * 种具有类型参数的泛型,它的类型参数表示的是从方法cao(而不是runO)中返回的值,并且
 *      * 必须使用 ExecutorService. submit0方法调用它,下面是一个简单示例
 * @Author LIBOFEI
 * @Date 2020/6/8 08:44
 * @Version 1.0
 **/
public class TaskWithResult implements Callable<String> {

    private int id;
    public TaskWithResult(int id){
        this.id = id;
    }
    public String call(){
        return "result of TaskWithResult : " + id;
    }
}
/** *
 * @Description submite0方法会产生 Future对象,它用 Callable返回结果的特定类型进行了参数化。你可以
 * 用 idOneo方法来查询 Future是否已经完成。当任务完成时,它具有一个结果,你可以调用geto
 * 方法来获取该结果。你也可以不用 idOneo进行检查就直接调用getO,在这种情况下,get0将阻
 * 塞,直至结果准备就绪。你还可以在试图调用geto来获取结果之前,先调用具有超时的getO,
 * 或者调用 isDone0来查看任务是否完成。
 * @Author LIBOFEI
 * @Date 08:51 2020/6/8
 * @Version  1.0
**/
class CallableDemo{
    public static void main(String[] args) {
        ExecutorService service = Executors.newCachedThreadPool();
        ArrayList<Future<String>> results = new ArrayList<>();
        for(int i = 0; i < 10;i++){
            results.add(service.submit(new TaskWithResult(i)));
        }
        for(Future<String> fs : results){
            try {
                System.out.println(fs.get());
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            } finally {
                service.shutdown();
            }
        }
    }
}
